package com.yunchuang.service;

import com.yunchuang.utils.ProfileUtils;
import org.apache.commons.io.monitor.FileAlterationMonitor;
import org.apache.commons.io.monitor.FileAlterationObserver;

import java.util.concurrent.TimeUnit;

/**
 * @author xct
 * @date 2023年03月28日 13:48
 * @Description 测试
 */
public class FileMonitorService {

    public void startListener() {
        // 文件目录
        String rootDir = ProfileUtils.getContext();
        // 间隔时间5秒
        long intervalTime = TimeUnit.SECONDS.toMillis(5);

        FileAlterationObserver observer = new FileAlterationObserver(rootDir);
        // 添加文件监听
        observer.addListener(new FileListenerService());
        // 创建文件监听者
        FileAlterationMonitor monitor = new FileAlterationMonitor(intervalTime, observer);

        // 启动监听
        try {
            monitor.start();
        } catch (Exception e) {
            e.printStackTrace();
        }

        //设置关闭时间
//        Thread.sleep(3000);
//        monitor.stop();

    }
}
